package com.zsr.rabbitmq.five;

import com.rabbitmq.client.Channel;
import com.zsr.rabbitmq.utils.RabbitMqUtils;

import java.util.Scanner;

/**
 * 生产者 发送消息给两个消费者
 * @author zsr
 * @date 2021/8/6 22:12
 */
public class EmitLog {
    public static final String EXCHANGE_NAME="logs";

    public static void main(String[] args) throws Exception{
        Channel channel = RabbitMqUtils.getChannel();
        //声明一个fanout交换机
        channel.exchangeDeclare(EXCHANGE_NAME,"fanout");
        Scanner scanner=new Scanner(System.in);
        while (scanner.hasNext()){
            String message = scanner.next();
            /**
             * 发布消息
             * 1.交换机的名字
             * 2.routingKey（两个消费者都接收到消息，和修改routingKey无关系）
             *      广播模式不管路由键，将消息派发给对应的绑定了交换器的所有消息队列。
             * 3.其他参数
             * 4.消息体
             */
            channel.basicPublish(EXCHANGE_NAME,"",null,message.getBytes("UTF-8"));
            System.out.println("发送成功");
        }
    }
}
